package com.holly.unit.kafka.model;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.ToString;

/**
 * localThread 存储，为了跨线程隔离
 * @author yangpengpeng
 *
 */
@Data
@ToString
@AllArgsConstructor
public class KlocalThread {
	/**
	 * 如果是普通producer，则代表线程id
	 * 如果是事务producer 则代表事务id
	 */
	private String keyId;
	/**
	 * 类型procucer 类型
	 */
	private KproducerType type;

	
	
}
